package com.its.common.kafka.annotation;

import org.springframework.stereotype.Component;

import java.lang.annotation.*;

/**
 * @Author xiaxp
 * @Date 2021-12-27 10:31
 * @Description
 */
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Component
public @interface KafkaHandler {
    String bootstrapServers();
    String topic();
    String groupId();
    int workNum() default 4;

    String securityProtocol() default ""; // "SASL_PLAINTEXT"

    String mechanism() default ""; // "SCRAM-SHA-256"

    String username() default "";

    String password() default "";
}
